google.golang.org/grpc/internal/balancer/gracefulswitch.balancerWrapper.gsb (field)
39 uses
google.golang.org/grpc/internal/balancer/gracefulswitch (current package)
gracefulswitch.go#L104: gsb: gsb,
gracefulswitch.go#L251: gsb *Balancer
gracefulswitch.go#L259: bw.gsb.mu.Lock()
gracefulswitch.go#L261: bw.gsb.mu.Unlock()
gracefulswitch.go#L282: bw.gsb.mu.Lock()
gracefulswitch.go#L284: bw.gsb.cc.RemoveSubConn(sc)
gracefulswitch.go#L286: bw.gsb.mu.Unlock()
gracefulswitch.go#L293: bw.gsb.mu.Lock()
gracefulswitch.go#L294: defer bw.gsb.mu.Unlock()
gracefulswitch.go#L297: if !bw.gsb.balancerCurrentOrPending(bw) {
gracefulswitch.go#L301: if bw == bw.gsb.balancerCurrent {
gracefulswitch.go#L307: if state.ConnectivityState != connectivity.Ready && bw.gsb.balancerPending != nil {
gracefulswitch.go#L308: bw.gsb.swap()
gracefulswitch.go#L317: bw.gsb.cc.UpdateState(state)
gracefulswitch.go#L325: if state.ConnectivityState != connectivity.Connecting || bw.gsb.balancerCurrent.lastState.ConnectivityState != connectivity.Ready {
gracefulswitch.go#L326: bw.gsb.swap()
gracefulswitch.go#L331: bw.gsb.mu.Lock()
gracefulswitch.go#L332: if !bw.gsb.balancerCurrentOrPending(bw) {
gracefulswitch.go#L333: bw.gsb.mu.Unlock()
gracefulswitch.go#L336: bw.gsb.mu.Unlock()
gracefulswitch.go#L338: sc, err := bw.gsb.cc.NewSubConn(addrs, opts)
gracefulswitch.go#L342: bw.gsb.mu.Lock()
gracefulswitch.go#L343: if !bw.gsb.balancerCurrentOrPending(bw) { // balancer was closed during this call
gracefulswitch.go#L344: bw.gsb.cc.RemoveSubConn(sc)
gracefulswitch.go#L345: bw.gsb.mu.Unlock()
gracefulswitch.go#L349: bw.gsb.mu.Unlock()
gracefulswitch.go#L356: if bw != bw.gsb.latestBalancer() {
gracefulswitch.go#L359: bw.gsb.cc.ResolveNow(opts)
gracefulswitch.go#L363: bw.gsb.mu.Lock()
gracefulswitch.go#L364: if !bw.gsb.balancerCurrentOrPending(bw) {
gracefulswitch.go#L365: bw.gsb.mu.Unlock()
gracefulswitch.go#L368: bw.gsb.mu.Unlock()
gracefulswitch.go#L369: bw.gsb.cc.RemoveSubConn(sc)
gracefulswitch.go#L373: bw.gsb.mu.Lock()
gracefulswitch.go#L374: if !bw.gsb.balancerCurrentOrPending(bw) {
gracefulswitch.go#L375: bw.gsb.mu.Unlock()
gracefulswitch.go#L378: bw.gsb.mu.Unlock()
gracefulswitch.go#L379: bw.gsb.cc.UpdateAddresses(sc, addrs)
gracefulswitch.go#L383: return bw.gsb.cc.Target()
The pages are generated with Golds v0.4.9. (GOOS=linux GOARCH=amd64)